package cn.it.hbtt.dao.impl;

import cn.it.hbtt.dao.BaseDAO;
import cn.it.hbtt.dao.UserDAO;
import cn.it.hbtt.entity.User;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class UserDAOImpl extends BaseDAO implements UserDAO {

    private Connection conn;
    private PreparedStatement pstm;
    private ResultSet rs;
    @Override
    public User login(User user) {

        try {
            //程序到这是不是就跟数据库打交道

            conn = super.getConnection();

            //登录 就是一个什么过程 就是拿着你的账号 密码 去数据库查询
            //如果能查到  表示有这个账号并且输入正确
            //如果查不到结果  表示可能没有也可能输入错误

            String sql="select *  from petowner where name=? and password=?";
            pstm=conn.prepareStatement(sql);
            //给第一个占位符赋值
            pstm.setObject(1, user.getUsername());
            //给第二个占位符赋值，赋值为参数对象的pwd属性值
            pstm.setObject(2, user.getPwd());

            rs = pstm.executeQuery();
            User loginUser=null;
            if(rs.next()){
                loginUser = new User();
                loginUser.setUsername(rs.getString("name"));
                loginUser.setPwd(rs.getString("password"));
            }
            return  loginUser;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
}
